package com.gitee.Transformation

import org.apache.flink.api.scala.ExecutionEnvironment

/*
连接两个表
 */
object UnionTset {
  def main(args: Array[String]): Unit = {
    val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment
    env.setParallelism(1)
    import org.apache.flink.api.scala._
    val data01: DataSet[String] = env.fromElements("spark", "flink")
    val data02: DataSet[String] = env.fromElements("hadoop", "flink")

    val data3: DataSet[String] = data01.union(data02)

    data3.print()
  }

}
